const fs = require('fs');
const server = require("http").createServer();

server.on("request",(req,res)=>{
    // fs.readFile("../txt/input.txt",(err,data)=>{
    //     if(err) console.log(err);
    //     res.end(data);
    // })
    // 流文件读取 实际过程中 读与写的速度并不统一 可能会发生背压

    // const readable = fs.createReadStream("../txt/input.txt");
    // readable.on('data',(chunk)=>{
    //     res.write(chunk);
    // })
    // readable.on('end',()=>{
    //     res.end();
    // })
    // readable.on('error',err=>{
    //     console.log(err);
    //     res.statusCode = 500;
    //     res.end("File not found");
    // })

    // pipe管道流 自动处理速度
    const readable = fs.createReadStream("../txt/input.txt");
    readable.pipe(res);
})

server.listen(8000,"127.0.0.1",()=>{
    console.log("Listening.....");
})